package com.zkrt.upms.service;




import com.zkrt.upms.dto.InfluxDto;
import com.zkrt.upms.dto.InfluxNewDto;
import com.zkrt.upms.entity.AttributeData;

import java.util.Date;
import java.util.List;
import java.util.Map;

public interface InfluxdbService {

    //void writeProporty(AliMqTopic msg, DeviceB device);

    Object query(String flux, String code, Map<String, Object> map);


    Object query(String flux, String code);


    //void electricConsume(Map<String, Object> variables);

    Map<String, List<AttributeData>> getHistories(String bucket, InfluxDto influxDto,
                                                  Date start,
                                                  Date end);

    AttributeData getNew(String bucket, InfluxNewDto influxDto);

}
